from lib.celery_app import app

from tasks import Add, sub

app.config_from_object("conf.celery_conf")
# 添加task

app.tasks.register(Add())
app.tasks.register(sub())

if __name__ == '__main__':
    app.worker_main(['worker', '--loglevel=INFO'])
